package org.lemon.transport.context.data.queue;

import lombok.Data;
import org.lemon.transport.context.data.tenant.TenantId;

import java.io.Serializable;

@Data
public class Queue implements Serializable {

    private Long id;

    /**
     * 租户id
     */
    private TenantId tenantId;

    /**
     * 队列名称
     */
    private String name;

    /**
     * 队列topic
     */
    private String topic;

    /**
     * 消费间隔
     */
    private int pollInterval;

    /**
     * partitions
     */
    private int partitions;

    private boolean consumerPerPartition;

    private long packProcessingTimeout;

    /**
     * 提交策略
     */
    private SubmitStrategy submitStrategy;

    /**
     * 消息处理策略
     */
    private ProcessingStrategy processingStrategy;
}
